# -*- coding: utf-8 -*-

from datetime import timedelta
from celery.schedules import crontab

broker_url = 'redis://192.168.100.208:6379/5'
result_backend = 'mongodb://47.104.9.64:27017/celery'

task_serializer = 'json'
result_serializer = 'json'
accept_content = ['json']
# Timezone
timezone = 'Asia/Shanghai'
enable_utc = True

# import
imports = (
    'celeryapp.task1',
    'celeryapp.task2'
)


# schedules
beat_schedule = {
    'add-every-30-seconds': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (1,1 )                           # 任务函数参数
    },
     'add-every-30-seconds2': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (2, 2)                           # 任务函数参数
    },
    'add-every-30-seconds3': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (3, 3)                           # 任务函数参数
    },
     'add-every-30-seconds4': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (4, 4)                           # 任务函数参数
    },
    'add-every-30-seconds5': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (5, 5)                           # 任务函数参数
    },
     'add-every-30-seconds6': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (6, 6)                           # 任务函数参数
    },
    'add-every-30-seconds7': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (7, 8)                           # 任务函数参数
    },
     'add-every-30-seconds8': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (9, 9)                           # 任务函数参数
    },
    'add-every-30-seconds9': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (10, 10)                           # 任务函数参数
    },
     'add-every-30-seconds10': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (11, 11)                           # 任务函数参数
    },
    'add-every-30-seconds11': {
         'task': 'celeryapp.task1.GetInfoDh',
         'schedule': crontab(),       # 每 30 秒执行一次
         'args': (12, 12)                           # 任务函数参数
    }
}